package com.hujf.flink.window.TimeWindow;

import com.hujf.flink.ch05.MySource;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author hujf
 * @Date 2022/5/23 11:23
 * @Description TODO
 */
public class gundong {
    public static void main(String[] args) {
        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStream<String> input = environment.addSource(new MySource());
    }
}
